package cn.wanda.topologies.bases

import org.apache.spark.sql.SparkSession
import org.apache.spark.streaming.dstream.InputDStream

trait SparkStreamingTopology extends SparkTopology{

  def process (DStream:InputDStream[(String, String)],session: SparkSession)

}
